package com.serwer;

import com.notowania.*;


public class ProducerNotowSend {

	public ProducerNotowSend(String Id, String Data, String Nazwa, String KursBiezacy,
			String KursOdniesienia, String Zmiana, String KursOtwarcia, String KursMin, String KursMax,
			String Wolumen, String Wartosc)
	{
		System.out.println("test123");
		 String queueName = "notowania.queue";
         
	        ProducerNotow producer;       
	       
	        while(true){
	  
	            //Let's not create a billion messages per second :)
	            try {
	                Thread.sleep(1000);
	            } catch (InterruptedException e) {
	                e.printStackTrace();
	            }
	             
	            producer = new ProducerNotow();       
	            
	            //Create a Person object that will be sent the Consumer */
	            Notowania notow = new Notowania();
	          //  p1.setId(1);
	           // p1.setName(all);
	           // p1.setAddress("adresa");
	            notow.setId(Id);
	            notow.setData(Data);
	            notow.setNazwa(Nazwa);
	            notow.setKursBiezacy(KursBiezacy);
	            notow.setKursOdniesienia(KursOdniesienia);
	            notow.setZmiana(Zmiana);
	            notow.setKursOtwarcia(KursOtwarcia);
	            notow.setKursMin(KursMin);
	            notow.setKursMax(KursMax);
	            notow.setWolumen(Wolumen);
	            notow.setWartosc(Wartosc);
	             
	            producer.produceMessage(queueName, notow);
	        }
	 
	    
	}

}
